package com.kwdb.server.storage;

import com.kwdb.grpc.DataPoint;
import java.util.List;

/**
 * 存储引擎接口
 */
public interface StorageEngine {
    
    /**
     * 写入单条数据
     */
    void write(DataPoint dataPoint) throws Exception;
    
    /**
     * 批量写入数据
     */
    void writeBatch(List<DataPoint> dataPoints) throws Exception;
    
    /**
     * 关闭存储引擎
     */
    void shutdown();
}

